//package com.dw.service;
//
//import org.apache.rocketmq.client.exception.MQClientException;
//
//import java.util.concurrent.CompletableFuture;
//import java.util.function.BiConsumer;
//
//public interface MessageQueueService {
//    public boolean sendMessageBySync();
//
//    public void sendMessageByAsync();
//
//    public void sendMessageDelay();
//}
